package main

import (
	"fmt"
	"go_study/mq"
	"strconv"
	"time"
)

// 简单模式和work模式 push方法
func main() {

	go func() {
		count := 0
		for {
			mq.Publish("", "zbw", "hello"+strconv.Itoa(count))
			count++
			time.Sleep(1 * time.Second)
		}
	}()
	fmt.Println("hello")
	time.Sleep(600 * time.Second)
	// fmt.Println(net.IPv4zero)
}
